package flink.mysql_connect.cdc;

import io.debezium.data.Envelope;
import lombok.Data;

import java.util.Map;

@Data
public class CdcDataVO {

    /**
     * 库名
     */
    private String dbName;
    /**
     * 表明
     */
    private String tbName;
    /**
     * 操作类型
     */
    private Envelope.Operation operatorType;
    /**
     * 修改后数据
     */
    private Map<String,Object> afterMap;
    /**
     * 修改前数据
     */
    private Map<String,Object> beforeMap;

}
